5df096bb6c1c49da072ca19713fa66a5cae73449,product-service/src/main/java/io/vertx/blueprint/microservice/product/impl/ProductVerticle.java,ProductVerticle,start,#Future#,23
Before Change
// register the service proxy on event bus
ProxyHelper.registerService(ProductService.class, vertx, userService, ADDRESS);
// publish the service in the discovery infrastructure
publishEventBusService("product-eb-service", ADDRESS, ProductService.class, ar -> {
if (ar.failed()) {
future.fail(ar.cause());
} else {
logger.info("Product service published");
// we also publish jdbc source in the discovery infrastructure
publishJDBCDataSource("product-jdbc-data-source-service", config(), ar1 -> {
if (ar1.failed()) {
future.fail(ar1.cause());
} else {
future.complete();
logger.info("Product JDBC data source service published");
}
});
}
});
}
}
After Change
// register the service proxy on event bus
ProxyHelper.registerService(ProductService.class, vertx, userService, SERVICE_ADDRESS);
// publish the service in the discovery infrastructure
publishEventBusService(ProductService.SERVICE_NAME, SERVICE_ADDRESS, ProductService.class)
.compose(servicePublished -> publishJDBCDataSource("product-jdbc-data-source-service", config()))
.setHandler(future.completer());
}
}